package com.atguigu.realtime.util;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

/**
 * @Author lzc
 * @Date 2023/3/21 09:25
 */
public class RedisUtil {
    
    private static JedisPool pool;
    
    static {
        // 1. 使用连接池√ 2. 直接创建对象
        JedisPoolConfig config = new JedisPoolConfig();
        // 设置一些参数
        config.setMaxTotal(100);// 提供最大连接数
        config.setMaxIdle(10);  // 最大允许的空闲连接数
        config.setMinIdle(2);// 最小允许的空闲连接数
        config.setMaxWaitMillis(10000); // 最大等待时间
    
        config.setTestOnCreate(true);  // 连接创建成功之后是否进行测试: ping
        config.setTestOnBorrow(true);
        config.setTestOnReturn(true);
        
        pool = new JedisPool(config, "hadoop162", 6379);
    }
    public static Jedis getRedisClient(){
        Jedis jedis = pool.getResource();
        jedis.select(8);
        return jedis;
    }
    
}
